package com.arch.flink.archetype.sinkprovider;

import java.util.Optional;

/**
 * @author pizhihui
 * @date 2023-08-03 14:12
 */
public interface MyParallelismProvider {


    default Optional<Integer> getParallelism() {
        return Optional.empty();
    }

}
